package com.tuniondata.netty.client;

import com.tuniondata.netty.bean.ApiBinaryBean;
import com.tuniondata.netty.bean.RpcMessage;
import com.tuniondata.netty.common.protocol.Protocol;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
 * @author yuxinchao
 */
public class ApiClientProcessor {
    private static final Logger log = LoggerFactory.getLogger(ApiClientProcessor.class);

    RpcMessage process(RpcMessage rpcMessage) throws Exception {
        RpcMessage res = new RpcMessage();
        res.setRequestId(rpcMessage.getRequestId());
        Protocol protocol = rpcMessage.getProtocol();
        switch (protocol.getMessageType()) {
            // 应答报文
            case "4008":
                log.info("收到服务器应答报文4008");

                break;
            // 断点通知报文
            case "4005": {
                // TODO
                break;
            }
            // 文件断点通知报文
            case "4003": {
                // TODO
                break;
            }
            // 文件数据报文
            case "4004": {
                // TODO
                break;
            }
            // 文件结束报文
            case "4007": {
                // TODO
                break;
            }
        }

        return res;
    }
}
